d0dc597261b0b9949ecd26150cd30ef89ecc7a21,src/java/org/apache/cassandra/service/StorageProxy.java,StorageProxy,sendToHintedEndpoints,#RowMutation#Iterable#AbstractWriteResponseHandler#String#ConsistencyLevel#,751
Before Change
if (dcGroups != null)
{
MessageOut<RowMutation> message = rm.createMessage();
// for each datacenter, send the message to one node to relay the write to other replicas
for (Map.Entry<String, Collection<InetAddress>> entry: dcGroups.entrySet())
{
After Change
else
{
// belongs on a different server
if (message == null)
message = rm.createMessage();
String dc = DatabaseDescriptor.getEndpointSnitch().getDatacenter(destination);
// direct writes to local DC or old Cassandra versions